package com.lagou.boot;

import com.lagou.client.RPCConsumer;
import com.lagou.zk.MyClient;

import java.util.TreeMap;

public class ConsumerBoot {

    private static TreeMap<Integer,String> keyMap=new TreeMap<Integer,String>();


    public static void main(String[] args) throws Exception {
        MyClient myClient = new MyClient();
        RPCConsumer rpcConsumer = new RPCConsumer();
        rpcConsumer.initClient();
        rpcConsumer.startSend();
        myClient.start(rpcConsumer);

        Thread.sleep(Integer.MAX_VALUE);


    }

}
